#include "app_mqtt.h"
#include "log/log.h"
#include "unistd.h"

/**
 * @brief 接收回调函数
 * 
 * @param json 接收到的JSON字符串
 * @return int 0: 成功 -1: 失败
 */
static int recv_callback(char *json)
{
    log_debug("处理接收到的JSON字符串: %s", json);
    return 0;
}

int main(int argc, char const *argv[])
{
    // 初始化MQTT客户端
    app_mqtt_init();

    // 注册接收回调函数
    app_mqtt_registerRecvCallback(recv_callback);
    
    // 发送消息
    char *json = "{\"id\": 1, \"name\": \"lhd\"}";
    app_mqtt_send(json);

    // 等待50秒
    sleep(50);

    // 关闭MQTT客户端
    app_mqtt_close();

    return 0;
}